package com.bw.service;

import com.alibaba.fastjson.JSON;
import com.bw.domain.MyMessage;
import com.bw.util.ZzyUtils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.retry.annotation.Retryable;
import org.springframework.stereotype.Service;

/**
 * 消费者的 service       在消费者监听器的  onMessage 里调用
 */
@Service
@Slf4j
public class ConsumerService {


    @Retryable // 消费者 如果异常 会重试三次
    public void  doMsg(MyMessage message){

        System.out.println("消费者 接收到了消息,模拟异常------" + JSON.toJSONString(message));

        int i = 1/0;
        Integer type = message.getType();

        if (type == 1){
            String phone = message.getPhone();

            String msg = message.getMsg();

            ZzyUtils.sendSms(phone,msg,5);

        }else {
            // 发邮件


        }
    }
}
